package cn.hallele.bbts.core.module.kafka.serialization;

import cn.hallele.bbts.core.common.utils.BeanUtil;
import org.apache.kafka.common.serialization.Serializer;

/**
 * BBTSSerializer
 *
 * @author anle5
 * @since 2023/12/9 星期六 0:29
 */
public class BBTSSerializer implements Serializer<Object> {
    @Override
    public byte[] serialize(String topic, Object data) {
        return BeanUtil.bean2Byte(data);
    }
}
